export default class SocketService {
    /**
     * 单例模式
     */
    static instance = null
    static get Instance(){
        if(!this.instance){
           this.instance = new SocketService()
        }
        return this.instance
    }

    // 实例属性
    ws = null  // 和服务端连接的socket对象
    callbackMapping = {}  // 存储回调函数
    connected = false  // 标识是否连接成功  --重发数据的机制
    sendRetryCount = 0  // 记录重新发送数据的次数  --重发数据的机制
    connectRetryCount = 0  // 记录重新连接尝试的次数  --断开重连的机制

    // 定义连接服务器的方法
    connect() {
        // 连接服务器
        if(!window.WebSocket) {
            return console.log('您的浏览器不支持WebSocket')
        }
        this.ws = new WebSocket('ws://localhost:9998')

        // 连接服务端成功的事件
        this.ws.onopen = ()=>{
            console.log('连接服务端成功了')
            this.connected = true
            this.connectRetryCount = 0  // 重置重新连接的次数
        }

        // 连接服务端失败的事件 (或 当连接成功之后服务器关闭的情况)
        this.ws.onclose = ()=>{
            console.log('连接服务端失败了')
            this.connected = false

            // 延时,并重新连接websocket服务器
            this.connectRetryCount++
            setTimeout(()=>{
                this.connect()
            }, 500 * this.connectRetryCount)
        }

        // 得到服务端发送过来的数据
        this.ws.onmessage = msg=>{
            // 真正服务端发送过来的原始数据时在msg中的data字段
            console.log('从服务端获取到了数据')
            // console.log(msg.data)

            const recvData = JSON.parse(msg.data)
            // console.log(recvData)
            const socketType = recvData.socketType
            // 判断回调函数是否存在
            if(this.callbackMapping[socketType]) {
                const action = recvData.action

                if(action === 'getData') {
                    const realData = JSON.parse(recvData.data)
                    this.callbackMapping[socketType].call(this, realData)
                } else if(action === 'fullScreen'){
                    this.callbackMapping[socketType].call(this, recvData)
                } else if(action === 'themeChange'){
                    this.callbackMapping[socketType].call(this, recvData)
                }
            }
        }
    }

    // 回调函数的注册
    registerCallback(socketType, callBack) {  // socketType: 函数的唯一标识
        this.callbackMapping[socketType] = callBack
    }
    // 取消某一个回调函数
    unRegisterCallback(socketType) {
        // this.callbackMapping.remove(socketType)
        this.callbackMapping[socketType] = null
    }

    // 发送数据的方法
    send (data) {
        // 判断此时此刻有没有连接成功
        if(this.connected){
            this.sendRetryCount = 0
            this.ws.send(JSON.stringify(data))
        } else {
            this.sendRetryCount++
            // 没有连接成功,延时发送数据
            setTimeout(()=>{
                this.send(data)
            }, this.sendRetryCount * 500)
        }
    }
}











